package com.baishancloud.log.common.connector

import java.io.Serializable

/**
 *
 * @author ziqiang.wang
 * @date 2021/10/21 18:52
 */
package object file extends Serializable {

  /**
   * 必选<br>
   * 本地文件路径，使用绝对路径
   */
  val sourceFilePathP: String = "source.filePath"
  /**
   * 发送数据的时间间隔，默认为1秒一条，单位：毫秒
   */
  val sourceEmitIntervalMsP: String = "source.emitIntervalMs"
  /**
   * 数据分隔符号，默认为空字符串，不分割<br>
   * 如果要模拟k-v类型的kafka数据，则可以设置分隔符号来分隔文件中的每一行数据
   */
  val sourceDataSeparatorP: String = "source.dataSeparator"
}
